27df79bd2edeae135f534632f44ee32ffe65dfdc,mpush-netty/src/main/java/com/mpush/netty/server/NettyTCPServer.java,NettyTCPServer,createEpollServer,#Listener#,185

Before Change


    private void createEpollServer(Listener listener) {
        EpollEventLoopGroup bossGroup = new EpollEventLoopGroup(getBossThreadNum(), getBossThreadFactory());
        EpollEventLoopGroup workerGroup = new EpollEventLoopGroup(getWorkThreadNum(), getWorkThreadFactory());
        workerGroup.setIoRatio(getIoRate());
        createServer(listener, bossGroup, workerGroup, EpollServerSocketChannel.class);
    }

After Change



    private void createEpollServer(Listener listener) {
        EventLoopGroup bossGroup = getBossGroup();
        EventLoopGroup workerGroup = getWorkerGroup();

        if (bossGroup == null) {
            EpollEventLoopGroup epollEventLoopGroup = new EpollEventLoopGroup(getBossThreadNum(), getBossThreadFactory());
            epollEventLoopGroup.setIoRatio(100);
            bossGroup = epollEventLoopGroup;
        }

        if (workerGroup == null) {
            EpollEventLoopGroup epollEventLoopGroup = new EpollEventLoopGroup(getWorkThreadNum(), getWorkThreadFactory());
            epollEventLoopGroup.setIoRatio(getIoRate());
            workerGroup = epollEventLoopGroup;
        }